﻿using System;
using System.Collections;
using System.IO;
using System.Net;
using System.Net.Sockets;
using System.Threading;
using MontagsmalerApp.ViewModels;
using System.Reflection;
using System.Collections.Generic;
using System.Text;

namespace MontagsmalerApp.Utils {

    public class HttpProcessor {
        public TcpClient socket;        
        public HttpServer srv;

        private Stream inputStream;
        public StreamWriter outputStream;

        public String http_method;
        public String http_url;
        public String http_protocol_versionstring;
        public Hashtable httpHeaders = new Hashtable();


        private static int MAX_POST_SIZE = 10 * 1024 * 1024; // 10MB

        public HttpProcessor(TcpClient s, HttpServer srv) {
            this.socket = s;
            this.srv = srv;                   
        }
        

        private string streamReadLine(Stream inputStream) {
            int next_char;
            string data = "";
            while (true) {
                next_char = inputStream.ReadByte();
                if (next_char == '\n') { break; }
                if (next_char == '\r') { continue; }
                if (next_char == -1) { Thread.Sleep(1); continue; };
                data += Convert.ToChar(next_char);
            }            
            return data;
        }
        public void process() {                        
            // we can't use a StreamReader for input, because it buffers up extra data on us inside it's
            // "processed" view of the world, and we want the data raw after the headers
            inputStream = new BufferedStream(socket.GetStream());

            // we probably shouldn't be using a streamwriter for all output from handlers either
            outputStream = new StreamWriter(new BufferedStream(socket.GetStream()));
            try {
                parseRequest();
                readHeaders();
                if (http_method.Equals("GET")) {
                    handleGETRequest();
                } else if (http_method.Equals("POST")) {
                    handlePOSTRequest();
                }
            } catch (Exception e) {
                Console.WriteLine("Exception: " + e.ToString());
                writeFailure();
            }
            outputStream.Flush();
            // bs.Flush(); // flush any remaining output
            inputStream = null; outputStream = null; // bs = null;            
            socket.Close();             
        }

        public void parseRequest() {
            String request = streamReadLine(inputStream);
            string[] tokens = request.Split(' ');
            if (tokens.Length != 3) {
                throw new Exception("invalid http request line");
            }
            http_method = tokens[0].ToUpper();
            http_url = tokens[1];
            http_protocol_versionstring = tokens[2];

            Console.WriteLine("starting: " + request);
        }

        public void readHeaders() {
            Console.WriteLine("readHeaders()");
            String line;
            while ((line = streamReadLine(inputStream)) != null) {
                if (line.Equals("")) {
                    Console.WriteLine("got headers");
                    return;
                }
                
                int separator = line.IndexOf(':');
                if (separator == -1) {
                    throw new Exception("invalid http header line: " + line);
                }
                String name = line.Substring(0, separator);
                int pos = separator + 1;
                while ((pos < line.Length) && (line[pos] == ' ')) {
                    pos++; // strip any spaces
                }
                    
                string value = line.Substring(pos, line.Length - pos);
                Console.WriteLine("header: {0}:{1}",name,value);
                httpHeaders[name] = value;
            }
        }

        public void handleGETRequest() {
            srv.handleGETRequest(this);
        }

        private const int BUF_SIZE = 4096;
        public void handlePOSTRequest() {
            // this post data processing just reads everything into a memory stream.
            // this is fine for smallish things, but for large stuff we should really
            // hand an input stream to the request processor. However, the input stream 
            // we hand him needs to let him see the "end of the stream" at this content 
            // length, because otherwise he won't know when he's seen it all! 

            Console.WriteLine("get post data start");
            int content_len = 0;
            MemoryStream ms = new MemoryStream();
            if (this.httpHeaders.ContainsKey("Content-Length")) {
                 content_len = Convert.ToInt32(this.httpHeaders["Content-Length"]);
                 if (content_len > MAX_POST_SIZE) {
                     throw new Exception(
                         String.Format("POST Content-Length({0}) too big for this simple server",
                           content_len));
                 }
                 byte[] buf = new byte[BUF_SIZE];              
                 int to_read = content_len;
                 while (to_read > 0) {  
                     Console.WriteLine("starting Read, to_read={0}",to_read);

                     int numread = this.inputStream.Read(buf, 0, Math.Min(BUF_SIZE, to_read));
                     Console.WriteLine("read finished, numread={0}", numread);
                     if (numread == 0) {
                         if (to_read == 0) {
                             break;
                         } else {
                             throw new Exception("client disconnected during post");
                         }
                     }
                     to_read -= numread;
                     ms.Write(buf, 0, numread);
                 }
                 ms.Seek(0, SeekOrigin.Begin);
            }
            Console.WriteLine("get post data end");
            srv.handlePOSTRequest(this, new StreamReader(ms));

        }

        public void writeSuccess() {
            outputStream.Write("HTTP/1.0 200 OK\n");
            outputStream.Write("Content-Type: text/html\n");
            outputStream.Write("Connection: close\n");
            outputStream.Write("\n");
        }

        public void writeFailure() {
            outputStream.Write("HTTP/1.0 404 File not found\n");
            outputStream.Write("Connection: close\n");
            outputStream.Write("\n");
        }
    }

    public abstract class HttpServer {

        protected int port;
        TcpListener listener;
        bool is_active = true;
       
        public HttpServer(int port) {
            this.port = port;
        }

        public void listen() 
        {
            //listener = new TcpListener(IPAddress.Parse("127.0.0.1"), port);
          listener = new TcpListener(IPAddress.Any, port);
            listener.Start();
            while (is_active) 
            {
              try
              {
                TcpClient s = listener.AcceptTcpClient();
                HttpProcessor processor = new HttpProcessor(s, this);
                Thread thread = new Thread(new ThreadStart(processor.process));
                thread.Start();
              }
              catch
              {

              }
              Thread.Sleep(1);
            }
        }

      public void Stop()
      {
        is_active = false;
        listener.Server.Close();
      }

        public abstract void handleGETRequest(HttpProcessor p);
        public abstract void handlePOSTRequest(HttpProcessor p, StreamReader inputData);
    }

    public class MyHttpServer : HttpServer 
    {
      Spiel spiel;
        public MyHttpServer(int port, Spiel spiel)
            : base(port) 
        {
          this.spiel = spiel;
        }

        public override void handleGETRequest(HttpProcessor p)
        {
          Console.WriteLine("request: {0}", p.http_url);

          // Standardseite unter Root ausgeben
          if (p.http_url == "/")
          {
            p.writeSuccess();
            p.outputStream.WriteLine("<html>");

            p.outputStream.WriteLine("<head>");
            p.outputStream.WriteLine("<meta id=\"viewport\" name=\"viewport\" content=\"width=320; initial-scale=1.0; maximum-scale=1.0; user-scalable=0;\">");
            p.outputStream.WriteLine("</head>");


            p.outputStream.WriteLine("<body>");
            p.outputStream.WriteLine("<Center>");

            p.outputStream.WriteLine("<h2>Montagsmaler</h2>");

            p.outputStream.WriteLine("Spiel: " + (spiel.SpielLaeuftGerade ? "l&auml;uft" : "beendet") + "&nbsp;");
            p.outputStream.WriteLine("Malrunde: " + (spiel.MalrundeLaeuftGerade ? "l&auml;uft" : "beendet") + "<br/>");

            //p.outputStream.WriteLine("Aktueller Begriff:" + spiel.AktuellerBegriff + "<br/>");
            p.outputStream.WriteLine("<h3>Aktueller Spieler: " + (spiel.AktuellerSpieler == null ? "-" : spiel.AktuellerSpieler.ToString()) + "</h3>");
            p.outputStream.WriteLine("Antworten: " + spiel.RichtigeAntworten + " richtig ");
            p.outputStream.WriteLine("" + spiel.FalscheAntworten + " falsch<br/>");

            p.outputStream.WriteLine("<br/>");

            p.outputStream.WriteLine("Teams<br/>");

            p.outputStream.WriteLine("<table style=\"border:1px solid #000; vertical-align:top; overflow:hidden;\">");
            p.outputStream.WriteLine("<tr bgColor=\"Silver\">");

            int iMaxSpieler = 0;

            // Überschrift - Teams ausgeben und max. Anzahl Spiele in einem Team feststellen
            for (int i = 0; i < spiel.Spielerverwaltung.Spielerteams.Count; i++)
            {
              p.outputStream.WriteLine("<td>" + spiel.Spielerverwaltung.Spielerteams[i].ToString() + "</td>");

              if (spiel.Spielerverwaltung.Spielerteams[i].Einzelspieler.Count > iMaxSpieler)
                iMaxSpieler = spiel.Spielerverwaltung.Spielerteams[i].Einzelspieler.Count;
            }

            p.outputStream.WriteLine("</tr>");

            // Jetzt die Teammitspiele ausgeben
            for (int j = 0; j < iMaxSpieler; j++)
            {
              p.outputStream.WriteLine("<tr>");
              for (int i = 0; i < spiel.Spielerverwaltung.Spielerteams.Count; i++)
              {
                if (spiel.Spielerverwaltung.Spielerteams[i].Einzelspieler.Count > j)
                  p.outputStream.WriteLine("<td>" + spiel.Spielerverwaltung.Spielerteams[i].Einzelspieler[j].ToString() + "</td>");
                else
                  p.outputStream.WriteLine("<td>&nbsp;</td>");
              }
              p.outputStream.WriteLine("</tr>");
            }

            p.outputStream.WriteLine("</table>");

            p.outputStream.WriteLine("</Center>");
            p.outputStream.WriteLine("</body></html>");

            //p.outputStream.WriteLine("Current Time: " + DateTime.Now.ToString());
            //p.outputStream.WriteLine("url : {0}", p.http_url);

            //p.outputStream.WriteLine("<form method=post action=/form>");
            //p.outputStream.WriteLine("<input type=text name=foo value=foovalue>");
            //p.outputStream.WriteLine("<input type=submit name=bar value=barvalue>");
            //p.outputStream.WriteLine("</form>");
          }
          else
          {
            //// Den Rest von Platte laden
            //string rootPath = Path.GetDirectoryName(Assembly.GetExecutingAssembly().Location);
            //string filename = Path.Combine(rootPath, Path.GetFileName(p.http_url));
            //if (File.Exists(filename))
            //{
            //  //Byte[] fileData = File.ReadAllBytes(filename);

            //  //List<byte> dataToSend = new List<byte>();
            //  //dataToSend.AddRange(BitConverter.GetBytes(Encoding.Unicode.GetByteCount(Path.GetFileName(filename)))); // length of filename 
            //  //dataToSend.AddRange(Encoding.Unicode.GetBytes(Path.GetFileName(filename))); // filename 
            //  //dataToSend.AddRange(fileData); // file binary data 

            //  //p.outputStream.Write(dataToSend.ToArray());
            //  p.outputStream.Write(File.ReadAllBytes(filename));
            //}
            //else
            //{
              p.writeFailure();
            //}
          }
        }

        public override void handlePOSTRequest(HttpProcessor p, StreamReader inputData) 
        {
            Console.WriteLine("POST request: {0}", p.http_url);
            string data = inputData.ReadToEnd();

            p.outputStream.WriteLine("<html><body><h1>test server</h1>");
            p.outputStream.WriteLine("<a href=/test>return</a><p>");
            p.outputStream.WriteLine("postbody: <pre>{0}</pre>", data);
            

        }
    }
}



